package com.celeritymq.factory;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

public class FactoryContainerImpl implements FactoryContainer {

	ConcurrentMap<String, CelerityQueueConnectionFactory> queueFactory = new ConcurrentHashMap<String, CelerityQueueConnectionFactory>();
	ConcurrentMap<String, CelerityTopicConnectionFactory> topicFactory = new ConcurrentHashMap<String, CelerityTopicConnectionFactory>();

	@Override
	public CelerityQueueConnectionFactory getQueueFactory(String factoryName) {
		return queueFactory.get(factoryName);
	}

	@Override
	public CelerityTopicConnectionFactory getTopicFactory(String factoryName) {
		return topicFactory.get(factoryName);
	}

	@Override
	public void initialize() {
		// TODO Auto-generated method stub

	}

}
